
mkdir -p /data/k8s/kubeflow/pipeline/workspace /data/k8s/kubeflow/pipeline/archives /data/k8s/infra/mysql
mkdir -p /data/k8s/monitoring/grafana/ /data/k8s/monitoring/prometheus/
chmod -R 777 /data/k8s/monitoring/grafana/ /data/k8s/monitoring/prometheus/

nodes=$1



if [ `kubectl get node|grep -v NAME|wc -l` -gt 2 ];then
  for node in $nodes;do
    # efk分布式目录创建
    ssh root@${node} mkdir -pv /data/efk-es{1..3}
    # alluxio挂载目录
    ssh root@${node} mkdir -pv /data/{alluxio,alluxio-domain}
    # alluxio内存缓存目录
    ssh root@${node} mkdir -pv /mnt/memory
    ssh root@${node} mount -t ramfs -o size=20G ramfs /mnt/memory
    # minio分布式目录
    ssh root@${node} mkdir -pv /data/minio{1..6}
    # kafka集群目录
    ssh root@${node} mkdir -pv /data/kafka{1..3}
    # zookeeper集群目录
    ssh root@${node} mkdir -pv /data/zk{1..3}
  done
else
  # 单机版本目录创建
  mkdir -pv /data/efk-es1
  mkdir -pv /data/efk-es2
  mkdir -pv /data/efk-es3
  mkdir -pv /data/minio
  mkdir -pv /data/alluxio-domain
  mkdir -pv /data/alluxio
  mkdir -pv /data/zk
  mkdir -pv /data/kafka
  mkdir -pv /mnt/memory
  mount -t ramfs -o size=20G ramfs /mnt/memory
fi


# 拉取镜像
sh pull_image_on_taichu_kubeflow.sh


